google.golang.org/grpc/internal/transport.http2Server.controlBuf (field)
40 uses
google.golang.org/grpc/internal/transport (current package)
http2_server.go#L87: controlBuf *controlBuffer
http2_server.go#L291: t.controlBuf = newControlBuffer(t.done)
http2_server.go#L340: t.loopy = newLoopyWriter(serverSide, t.framer, t.controlBuf, t.bdpEst, t.conn, t.logger, t.outgoingGoAwayHandler, t.bufferPool)
http2_server.go#L378: t.controlBuf.put(&cleanupStream{
http2_server.go#L482: t.controlBuf.put(&earlyAbortStream{
http2_server.go#L493: t.controlBuf.put(&cleanupStream{
http2_server.go#L502: t.controlBuf.put(&earlyAbortStream{
http2_server.go#L512: t.controlBuf.put(&earlyAbortStream{
http2_server.go#L557: t.controlBuf.put(&cleanupStream{
http2_server.go#L572: t.controlBuf.put(&earlyAbortStream{
http2_server.go#L593: t.controlBuf.put(&earlyAbortStream{
http2_server.go#L607: t.controlBuf.put(&earlyAbortStream{
http2_server.go#L659: t.controlBuf.put(®isterStream{
http2_server.go#L676: t.controlBuf.throttle()
http2_server.go#L690: t.controlBuf.put(&cleanupStream{
http2_server.go#L707: t.controlBuf.put(&goAway{
http2_server.go#L754: t.controlBuf.put(&outgoingWindowUpdate{streamID: s.id, increment: w})
http2_server.go#L764: t.controlBuf.put(&outgoingWindowUpdate{streamID: s.id,
http2_server.go#L780: t.controlBuf.put(&outgoingWindowUpdate{
http2_server.go#L784: t.controlBuf.put(&outgoingSettings{
http2_server.go#L810: t.controlBuf.put(&outgoingWindowUpdate{
http2_server.go#L819: t.controlBuf.put(&outgoingWindowUpdate{
http2_server.go#L824: t.controlBuf.put(bdpPing)
http2_server.go#L842: t.controlBuf.put(&outgoingWindowUpdate{s.id, w})
http2_server.go#L872: t.controlBuf.put(&cleanupStream{
http2_server.go#L898: t.controlBuf.executeAndPut(func() bool {
http2_server.go#L927: t.controlBuf.put(pingAck)
http2_server.go#L958: t.controlBuf.put(&goAway{code: http2.ErrCodeEnhanceYourCalm, debugData: []byte("too_many_pings"), closeConn: errors.New("got too many pings from the client")})
http2_server.go#L963: t.controlBuf.put(&incomingWindowUpdate{
http2_server.go#L1054: success, err := t.controlBuf.executeAndPut(func() bool { return t.checkForHeaderListSize(hf) }, hf)
http2_server.go#L1124: success, err := t.controlBuf.executeAndPut(func() bool {
http2_server.go#L1172: if err := t.controlBuf.put(df); err != nil {
http2_server.go#L1237: t.controlBuf.put(closeConnection{})
http2_server.go#L1260: t.controlBuf.put(p)
http2_server.go#L1293: t.controlBuf.finish()
http2_server.go#L1346: t.controlBuf.put(hdr)
http2_server.go#L1362: t.controlBuf.put(&cleanupStream{
http2_server.go#L1377: t.controlBuf.put(&goAway{code: http2.ErrCodeNo, debugData: []byte(debugData), headsUp: true})
http2_server.go#L1435: t.controlBuf.put(&goAway{code: g.code, debugData: g.debugData})
http2_server.go#L1465: t.controlBuf.put(&outFlowControlSizeRequest{resp})